const { pool, executeSql } = require("./db"); // 数据库连接池
const { queryOne, queryPage, insertOne, update, del, queryList } = require("./sqlUtils");
const TABLE_WHITE_LIST = ["user", "temp", "friend_list", "mingyue"]; // 白名单
exports.publish = async (options) => {
    const { userId, status } = options || {};

    const { success, data } = await queryOne(
        "friend_list", // 表名
        ["*"], // 查询字段
        { userId }, // 条件
        TABLE_WHITE_LIST // 白名单
    );
    console.log("result", success, data);

    if (success) {
        if (data.length === 0) {
            await insertOne(
                "friend_list", // 表名
                options, // 新增数据
                TABLE_WHITE_LIST // 白名单
            );
        } else {
            await update(
                "friend_list", // 表名
                options, // 新增数据
                { userId },
                TABLE_WHITE_LIST // 白名单
            );
        }
    }
};

exports.queryList = async (options) => {
    const { page, pageSize, channel } = options || {};

    const result = await queryPage(
        channel, // 表名
        {
            fields: ["*"],
            where: {},
            order: {
                timestamp: "ASC"
            },
            page,
            pageSize
        },
        TABLE_WHITE_LIST // 白名单
    );
    console.log("queryList", result.success, result.data, result.message);

    return result;
};

exports.queryMyPublish = async (options) => {
    const { userId, status } = options || {};
    const result = await queryOne(
        "friend_list", // 表名
        ["*"], // 查询字段
        { userId }, // 条件
        TABLE_WHITE_LIST // 白名单
    );
    console.log("cccccc", result);

    return result;
};
